Apache Flink-এর সাথে IntelliJ বা Eclipse IDE কনফিগার করার জন্য কিছু স্টেপ রয়েছে, যা ফলো করলে আপনি সহজেই Flink ডেভেলপমেন্ট শুরু করতে পারবেন। নিচে আমি দুইটি IDE (IntelliJ এবং Eclipse) তে Flink কনফিগার করার বিস্তারিত গাইড দিচ্ছি:
File
> New
> Project
সিলেক্ট করুন।Next
চাপুন।org.apache.flink
এবং flink-demo
).Next
এবং তারপর Finish
চাপুন।<dependencies>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>1.15.2</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.12</artifactId>
<version>1.15.2</version>
</dependency>
</dependencies>
নোট: আপনার প্রয়োজন অনুযায়ী Flink এর ভার্সন পরিবর্তন করতে পারেন।
FlinkJob
) এবং নিচের মতো একটি সিম্পল স্ট্রিমিং জব লিখুন:import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
public class FlinkJob {
public static void main(String[] args) throws Exception {
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.fromElements("Hello", "Flink")
.print();
env.execute("Flink Streaming Job");
}
}
Run
> Edit Configurations
ক্লিক করুন এবং নতুন Application কনফিগারেশন সেট করুন।FlinkJob
) সিলেক্ট করুন এবং Run
চাপুন।Next
করুন।org.apache.flink
এবং flink-demo
).<dependencies>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>1.15.2</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.12</artifactId>
<version>1.15.2</version>
</dependency>
</dependencies>
FlinkJob
) এবং উপরের মতো একটি সিম্পল স্ট্রিমিং জব লিখুন।log4j.properties
বা logback.xml
ফাইল ব্যবহার করতে পারেন।mvn clean install
রান করুন।এই স্টেপগুলো ফলো করলে আপনি সহজেই Flink ডেভেলপমেন্ট শুরু করতে পারবেন IntelliJ এবং Eclipse IDE তে।
আরও দেখুন...